tupleReceived = 0;
customGroupingInfoInPrepare = null;
testLooper.exitLoop();
slaveLooper.exitLoop();
threadsPool.shutdownNow();
tupleReceived = 0;
customGroupingInfoInPrepare = null;
if (testLooper != null) {
testLooper.exitLoop();
}
if (slaveLooper != null) {
slaveLooper.exitLoop();